package com.cn.base.嵌入Broler;

import org.apache.activemq.broker.BrokerService;

/**
 * @author: dlr
 * @data: 2019/8/19 23:08
 * @desc: 通过Broker嵌入Java代码启动MQ
 *
 * 当远程mq宕机 可手动自己写 一定要加入jackson-databind依赖
 */
public class stratMQBroker {

    public static void main(String[] args) throws Exception {

        BrokerService brokerService=new BrokerService();
        //确定嵌入java代码
        brokerService.setUseJmx(true);
        //自己的地址 类似绑定在虚拟机服务器上
        brokerService.addConnector("tcp://127.0.0.1:61616");
        //启动
        brokerService.start();

    }
}
